package com.song.article.stream;

import com.song.pojo.AppUser;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
@EnableBinding(MyStreamChannel.class)
public class MyStreamConsumer {

    @StreamListener(MyStreamChannel.INPUT)
    public void receive(AppUser user) {
        System.out.println(user);
    }
}

